//package baseFx.common.mq.rabbitmq;
//
//import com.rabbitmq.client.Channel;
//
//import java.io.IOException;
//import java.util.concurrent.TimeoutException;
//
//public class MqChannel extends ChannelWrapper {
//    private MqConnection connection;
//
//    public MqChannel(Channel channel, MqConnection connection) {
//        super(channel);
//        this.connection = connection;
//    }
//
//    private void returnToPool() {
//        if (connection != null) {
//            connection.returnChannel(this);
//            connection = null;
//        }
//    }
//
//    @Override
//    public void close() throws IOException, TimeoutException {
//        returnToPool();
//    }
//
//    @Override
//    public void close(int i, String s) throws IOException, TimeoutException {
//        returnToPool();
//    }
//
//    public void destroy() {
//        try {
//            super.close();
//        } catch (IOException | TimeoutException e) {
//            e.printStackTrace();
//        }
//    }
//}
